package com.hujf.flink.kafka;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;

/**
 * @Author hujf
 * @Date 2022/5/23 18:02
 * @Description TODO
 */
public class KafkaTest {
    public static void main(String[] args) {
        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();

       // new FlinkKafkaConsumer<>("myTopic"，)
    }
}
